"""
简单模式，P--Q--C
"""

# 获取MQ连接
from pingtai.mqdemo.mqutils import get_connection

connection = get_connection()

# 在连接上创建一个频道CHANNEL
channel = connection.channel()

# 声明队列QUEUE
channel.queue_declare(queue='simple_queue')

# 发送消息
channel.basic_publish(exchange='',  # 交换机
                      routing_key='simple_queue',  # 路由键，写明将消息发往哪个队列
                      body='Hello World!'  # 生产者要发送的消息
                      )
print("[生产者] send 'Hello World!'")

connection.close()  # 当生产者发送完消息后，可选择关闭连接
